package htfile

import (
	"core/corestruct"
	"core/server/kafkaserver"
	"core/server/pushserver"
)

const (
	TOPIC_HTFILE_UP = "iot-htfileup"
)

var (
	htFilePushServer *kafkaserver.PushServer
)

func init() {

	htFilePushServer = &kafkaserver.PushServer{
		Name:       "文件上传推送",
		Topic:      TOPIC_HTFILE_UP,
		PushServer: pushserver.PushServer{},
	}
	htFilePushServer.Start()
}
func PushHtfile(id int64, name string) {
	var m = corestruct.IdNameDto{Id: id, Name: name}
	htFilePushServer.Push("", m)
}
